import {Observable} from 'rxjs'

// 可以被观察
const observable = new Observable((subscriber)=>{
    subscriber.next(1);      //发出值
    subscriber.next(2);
    subscriber.next(3);
    subscriber.complete();       //完成
})

// .subscribe观察 observable被观察者
// subscription标识一个对observable的订阅
// 通过subscription，可以取消订阅，也可以组合多个订阅
const subscription = observable.subscribe({
    next(x){
        console.log('x',x)
    },
    error(err){
        console.error(err)
    },
    complete(){
        console.log('done.')
    }
})
